

package com.hazelcast.jet.pipeline;

import java.io.Serializable;

/**
 * A data sink in a Jet pipeline. It accepts the data the pipeline
 * processed and exports it to an external system.
 *
 * @param <T> the type of the data the sink will receive
 * @see Sinks sink factory methods
 * @since Jet 3.0
 */
public interface Sink<T> extends Serializable {

    /**
     * Returns a descriptive name for this sink.
     */
    String name();

}
